package com.nari.interplatform.mq;

import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;

/**
 * 读取mq相关配置
 *
 * @author cqb
 */
@EnableAutoConfiguration
@Component
@ConfigurationProperties(prefix = "mqserver")
public class MqConfig {
    private String namesrvAddr;
    private String producerGroup;
    private String consumerGroup;
    private String topicReq;
    private String topicResp;

    public void setNamesrvAddr(String namesrvAddr) {
        this.namesrvAddr = namesrvAddr;
    }

    public void setProducerGroup(String producerGroup) {
        this.producerGroup = producerGroup;
    }

    public void setConsumerGroup(String consumerGroup) {
        this.consumerGroup = consumerGroup;
    }

    public void setTopicReq(String topicReq) {
        this.topicReq = topicReq;
    }

    public void setTopicResp(String topicResp) {
        this.topicResp = topicResp;
    }

    public String getNamesrvAddr() {
        return namesrvAddr;
    }

    public String getProducerGroup() {
        return producerGroup;
    }

    public String getConsumerGroup() {
        return consumerGroup;
    }

    public String getTopicReq() {
        return topicReq;
    }

    public String getTopicResp() {
        return topicResp;
    }
}

